#!/bin/bash
dt=$(date -d '1 days ago' '+%Y-%m-%d')
#设置日志目录
LOG_DIR="/root/hive_logs"
# 创建日志目录
mkdir -p "$LOG_DIR"

#将ods层的数据增量追加到DWD层，顺序执行并分别记录日志
nohup hive -hivevar etl_dt="$dt" -f /root/hive_ods_dwd/inc_add.sql & > $LOG_DIR/inc_add.log 2>&1
if [ $? -ne 0 ];
then
	# 运行失败则退出
	echo "ods-dwd 增量追加报错"
	exit
fi

#将ods层的数据全量追加到DWD层，顺序执行并分别记录日志
nohup hive -hivevar etl_dt="$dt" -f /root/hive_ods_dwd/full_add.sql & > $LOG_DIR/full_add.log 2>&1
if [ $? -ne 0 ]; 
then
	# 运行失败则退出
	echo "ods-dwd 全量追加报错"
	exit
fi

#将dwd层的数据汇总到dws层，完成明细宽表
nohup hive -hivevar etl_dt="$dt" -f /root/hive_dwd_dws/dws_inc_add.sql & > $LOG_DIR/inc_add.log 2>&1
if [ $? -ne 0 ];
then
	# 运行失败则退出
	echo "dwd-dws 增量追加报错"
	exit
fi

#使用dws层的数据完成ads层-全量覆盖，客户风险全景视图
nohup hive -hivevar -f /root/hive_dwd_dws/ads_kh_risk.sql & > $LOG_DIR/inc_add.log 2>&1
if [ $? -ne 0 ];
then
	# 运行失败则退出
	echo "dws-ads 全量覆盖报错"
	exit
fi


echo "所有任务成功完成"